package com.kksoft.readcm.a;

import android.os.AsyncTask;
import android.os.Handler;
import com.kksoft.readcm.activity.App;
import com.kksoft.readcm.b.m;
import com.kksoft.readcm.b.n;
import com.kksoft.readcm.objects.ai;
import com.kksoft.readcm.objects.l;
import com.kksoft.readcm.service.WakefulAppService;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.Observable;
import java.util.Observer;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.RejectedExecutionException;
import java.util.concurrent.atomic.AtomicBoolean;

public final class y extends AppObservable
  implements com.kksoft.readcm.c.a, Observer
{
  private aj k;
  private int l = 0;
  private final com.kksoft.readcm.objects.a m;
  private final com.kksoft.readcm.objects.a n;
  private Handler o;
  private Thread p;
  private boolean q;
  private boolean r;
  private ConcurrentHashMap s;
  private ConcurrentHashMap t;
  private boolean u;
  private final Object v;
  private ArrayList w;
  private ai x;

  public y()
  {
    this.q = false;
    this.r = false;
    this.s = new ConcurrentHashMap();
    this.t = new ConcurrentHashMap();
    this.u = false;
    this.v = new Object();
    this.o = new Handler();
    this.x = new ai(App.s(), 300L);
    this.m = new com.kksoft.readcm.objects.a(this);
    this.n = new com.kksoft.readcm.objects.a(this);
    a();
  }
  
  private int a(l paraml, int paramInt1, int paramInt2, int paramInt3, boolean paramBoolean1, boolean paramBoolean2)
  {
    com.kksoft.readcm.b.h localh1 = paraml.b(paramInt1);
    if (localh1 != null)
    {
      int i;
      if (localh1.q())
      {
        i = -1;
        return i;
      }
//      if ((paramInt2 == 2) && (i.z() != 2))
//        i.n();
    }
//    label76: label87: label223: int i1;
//    label230: for (Object localObject2 = null; ; localObject2 = i1)
//    {
//      while (true)
//      {
//        com.kksoft.readcm.b.h localh2 = null;
//        switch (paramInt1)
//        {
//        default:
//          if (paramInt2 != 2)
//            break;
//        case 1:
//        case 2:
//        }
//        try
//        {
//          b(localh2);
//          while (true)
//          {
//            if (localObject2 != null)
//              break label223;
//            int j = 1;
//            break;
//            if (j.b() == paramInt3)
//              break label230;
//            j.a(paramInt3);
//            j = -1;
//            break;
//            int i2 = paramInt2;
//            int i3 = paramInt3;
//            y localy1 = this;
//            l locall1 = paraml;
//            boolean bool1 = paramBoolean1;
//            boolean bool2 = paramBoolean2;
//            Object localObject1 = new com.kksoft.readcm.b.k(i2, i3, localy1, locall1, bool1, bool2);
//            break label76;
//            int i4 = paramInt2;
//            int i5 = paramInt3;
//            y localy2 = this;
//            l locall2 = paraml;
//            boolean bool3 = paramBoolean1;
//            localObject1 = new n(i4, i5, localy2, locall2, bool3);
//            break label76;
//            this.m.b((com.kksoft.readcm.b.h)localObject1);
//          }
//        }
//        catch (RejectedExecutionException localRejectedExecutionException)
//        {
//          break label87;
//          i1 = -1;
//        }
//      }
//      break;
//    }
	return 0;
  }

  static com.kksoft.readcm.objects.a a(y y1)
  {
      return y1.m;
  }

  static void a(y y1, l l1, boolean flag, boolean flag1)
  {
      y y2 = y1;
      l l2 = l1;
      boolean flag2 = flag;
      boolean flag3 = flag1;
      boolean flag4 = false;
      y2.a(l2, flag2, flag3, 1, 2, false, flag4);
  }

  private void a(l l1, boolean flag, boolean flag1, int i1, int j1, boolean flag2, boolean flag3)
  {
      l1.a(true);
      boolean flag4;
      if(!flag && l1.G() && com.kksoft.readcm.objects.l.S() && i1 == 1)
          flag4 = true;
      else
          flag4 = flag;
      if(flag1 && (flag2 || l1.D() == 0 || u && l1.D() == -1))
      {
          y y1 = this;
          l l2 = l1;
          int k1 = i1;
          int i2 = j1;
          boolean flag5 = flag2;
          boolean flag6 = flag3;
          int j2 = y1.a(l2, 1, k1, i2, flag5, flag6);
      }
      if(flag4 && (flag2 || l1.C() == 0 || u && l1.C() == -1))
      {
          y y2 = this;
          l l3 = l1;
          int k2 = i1;
          int i3 = j1;
          boolean flag7 = flag2;
          boolean flag8 = flag3;
          int j3 = y2.a(l3, 2, k2, i3, flag7, flag8);
      }
  }

  static com.kksoft.readcm.objects.a b(y y1)
  {
      return y1.n;
  }

  private void b(com.kksoft.readcm.b.h paramh)
  {
    this.n.b(paramh);
  }

  private void g()
  {
	LoginObservable localal = this.h;
    com.kksoft.readcm.objects.GlobalVar localh = new com.kksoft.readcm.objects.GlobalVar(35);
    localal.a(localh);
  }

  public final com.kksoft.readcm.objects.y a(int paramInt, com.kksoft.readcm.b.h paramh)
  {
    if (paramInt == 2);
    for (com.kksoft.readcm.objects.a locala = this.n; ; locala = this.m)
      return locala.a(paramh);
  }

  public final void a()
  {
	  int i1;
      int j1;
      if(App.d())
          i1 = 2;
      else
          i1 = 1;
      j1 = l;
      if(i1 != j1)
      {
          l = i1;
          ad ad1 = new ad(this, i1);
          Void[] arrayOfVoid = new Void[0];
          AsyncTask localAsyncTask = ad1.execute(arrayOfVoid);
      }    
  }

  public final void a(int paramInt)
  {
    boolean bool1 = this.m.a(paramInt);
    boolean bool2 = this.n.a(paramInt);
  }

  public final void a(com.kksoft.readcm.b.h paramh)
  {
//    if (paramh == null);
//    l locall1;
////    do
////    {
////      return;
////      locall1 = paramh.t();
////    }
////    while (locall1 == null);
////    int i;
////    if ((!this.q.get()) && (!paramh.p()))
////    {
////      if (paramh.u())
////        break label240;
////      if (!paramh.v())
////        break label225;
////      i = 1;
//    }
//    while (true)
//    {
//      if (paramh.d() != 3)
//      {
//        e locale1 = this.c;
//        int j = paramh.d();
//        String str1 = paramh.x();
//        String str2 = paramh.y();
////        locale1.a(locall1, j, i, str1, str2, 0);
//        if (paramh.d() == 1)
//        {
//          if ((paramh.A() != null) && (paramh.A().size() > 0))
//          {
//            e locale2 = this.c;
//            HashMap localHashMap1 = paramh.A();
//            l locall2 = paramh.t();
//            locale2.a(localHashMap1, locall2);
//          }
//          if ((paramh.B() != null) && (paramh.B().size() > 0))
//          {
//            e locale3 = this.c;
//            HashMap localHashMap2 = paramh.B();
//            l locall3 = paramh.t();
//            locale3.b(localHashMap2, locall3);
//          }
//        }
//      }
//      if (paramh.d() != 1)
//        break;
////      com.kksoft.readcm.objects.h localh = new com.kksoft.readcm.objects.h(12, null, 0, paramh);
////      this.h.a(localh);
//      break;
//      label225: if (paramh.w() == -1)
//      {
//        i = -1;
//        continue;
//      }
//      label240: i = -1;
//    }
  }

  public final void a(com.kksoft.readcm.b.k paramk)
  {
//    if ((!paramk.p()) && (!paramk.q()))
//    {
//      if ((paramk.A() != null) && (paramk.A().size() > 0))
//      {
//        ConcurrentHashMap localConcurrentHashMap1 = this.s;
//        String str1 = paramk.s();
//        HashMap localHashMap1 = paramk.A();
//        Object localObject1 = localConcurrentHashMap1.put(str1, localHashMap1);
//      }
//      if ((paramk.B() != null) && (paramk.B().size() > 0))
//      {
//        ConcurrentHashMap localConcurrentHashMap2 = this.t;
//        String str2 = paramk.s();
//        HashMap localHashMap2 = paramk.B();
//        Object localObject2 = localConcurrentHashMap2.put(str2, localHashMap2);
//      }
//    }
//    com.kksoft.readcm.objects.h localh = new com.kksoft.readcm.objects.h(36, null, 0, paramk);
//    this.h.a(localh);
//    this.g.a(0);
  }

  public final void a(l paraml)
  {
//    synchronized (this.v)
//    {
//      if (this.w == null)
//      {
//        ArrayList localArrayList = new ArrayList();
//        this.w = localArrayList;
//      }
//      boolean bool = this.w.add(paraml);
//      ai localai = this.x;
//      ar localar = new ar(this);
//      localai.a(localar);
//      return;
//    }
  }

  public final void a(l paraml, boolean paramBoolean, int paramInt)
  {
//    this.c.a(paraml);
//    y localy = this;
//    l locall = paraml;
//    int i = paramInt;
//    boolean bool = paramBoolean;
//    int j = 0;
//    localy.a(locall, 1, 0, i, 4, bool, j);
  }

  public final void a(l paraml, boolean paramBoolean1, boolean paramBoolean2, boolean paramBoolean3)
  {
//    this.c.b(paraml, paramBoolean1, paramBoolean2);
//    y localy = this;
//    l locall = paraml;
//    boolean bool1 = paramBoolean1;
//    boolean bool2 = paramBoolean2;
//    boolean bool3 = paramBoolean3;
//    localy.a(locall, bool1, bool2, 2, 3, 1, bool3);
//    g();
  }

  public final void a(String paramString)
  {
//    com.kksoft.readcm.b.k localk = new com.kksoft.readcm.b.k(this, paramString);
//    b(localk);
//    g();
  }

  public final void a(boolean paramBoolean)
  {
//    if (this.r.get());
//    while (true)
//    {
//      return;
//      this.r.set(1);
//      g localg = new g(this, paramBoolean);
//      Void[] arrayOfVoid = new Void[0];
//      AsyncTask localAsyncTask = localg.execute(arrayOfVoid);
//    }
  }

  public final HashMap b(String paramString)
  {
    return (HashMap)this.s.get(paramString);
  }

  public final void b()
  {
//    if (this.q.get());
//    while (true)
//    {
//      return;
//      this.q.set(1);
//      al localal = this.h;
//      com.kksoft.readcm.objects.h localh = new com.kksoft.readcm.objects.h(30);
//      localal.a(localh);
//      i locali = new i(this);
//      Void[] arrayOfVoid = new Void[0];
//      AsyncTask localAsyncTask = locali.execute(arrayOfVoid);
//    }
  }

  public final void b(int paramInt)
  {
    boolean bool1 = this.m.b(paramInt);
    boolean bool2 = this.n.b(paramInt);
  }

  public final void b(m paramm)
  {
//    int i = l.P();
//    int j = l.O();
//    if (i == j)
//      l.N();
//    g();
  }

  public final void b(l paraml)
  {
    boolean bool1 = App.isDownWeb();
    boolean bool2 = App.isDownText();
    y localy = this;
    l locall = paraml;
    localy.a(locall, bool1, bool2, 1, 2, false, false);
  }

  public final HashMap c(String paramString)
  {
    return (HashMap)this.t.get(paramString);
  }

  public final boolean c()
  {
	  boolean flag;
      if(!q && (r || m.a() || n.a()))
          flag = true;
      else
          flag = false;
      return flag;
  }

  public final boolean d()
  {
	  boolean flag;
      if(!q && m.a())
          flag = true;
      else
          flag = false;
      return flag;
  }

  public final void e()
  {
    this.u = true;
  }

  public final void f()
  {
    if ((c()) && (this.p == null))
    {
      Thread localThread = new Thread(new Runnable(){

		@Override
		public void run() {
			// TODO Auto-generated method stub
			boolean bool1 = y.a(y.this).a(5);
		    boolean bool2 = y.b(y.this).a(5);
		    int i = 0;
		    while (true)
		    {
		      if (i >= 15)
		      {
		        WakefulAppService.a(2131165315);
		        y.this.b();
		        y.j(y.this);
		        boolean bool3 = y.a(y.this).b(5);
		        boolean bool4 = y.b(y.this).b(5);
		      }
		      else
		      {
		        long l = 1000L;
		        try
		        {
		          Thread.sleep(l);
		          if (App.isConnectNet())
		          {
		            boolean bool5 = y.a(y.this).b(5);
		            boolean bool6 = y.b(y.this).b(5);
		            y.j(y.this);
		          }
		        }
		        catch (InterruptedException localInterruptedException)
		        {
		          //while (true)
		            App.b(localInterruptedException);
		          i += 1;
		        }
		      }
		    }
		}});
      this.p = localThread;
      this.p.start();
    }
  }
  static void j(y y1)
  {
      y1.p = null;
  }
  public final void i()
  {
    super.i();
//    b();
//    f localf = new f(this);
//    Void[] arrayOfVoid = new Void[0];
//    AsyncTask localAsyncTask = localf.execute(arrayOfVoid);
  }

  public final void update(Observable paramObservable, Object paramObject)
  {
//    switch (com.kksoft.readcm.objects.h.a(paramObject).a())
//    {
//    default:
//    case 60:
//    }
//    while (true)
//    {
//      return;
//      if (this.k != null)
//      {
//        Handler localHandler1 = this.o;
//        aj localaj1 = this.k;
//        localHandler1.removeCallbacks(localaj1);
//      }
//      switch (App.c())
//      {
//      case 2:
//      default:
//        break;
////      case 1:
////        aj localaj2 = new aj(this);
////        this.k = localaj2;
////        Handler localHandler2 = this.o;
////        aj localaj3 = this.k;
////        boolean bool1 = localHandler2.postDelayed(localaj3, 1000L);
////        break;
////      case 3:
////        aj localaj4 = new aj(this);
////        this.k = localaj4;
////        Handler localHandler3 = this.o;
////        aj localaj5 = this.k;
////        boolean bool2 = localHandler3.postDelayed(localaj5, 4000L);
//      }
//    }
  }

}